//package com.shou.domain.xxx.service.Impl;
//
//import com.shou.domain.xxx.adapter.IMqServiceAdapter;
//import com.shou.domain.xxx.service.IMqTest;
//import jakarta.annotation.Resource;
//import org.springframework.stereotype.Service;
//
//import java.time.LocalDateTime;
//
//@Service("mqTest")
//public class MqTest implements IMqTest {
//
//    @Resource
//    private IMqServiceAdapter mqServiceAdapter;
//
//    @Override
//    public void testSendMqMessage() {
//        mqServiceAdapter.sendMessage("test-topic", "sendMessage" + LocalDateTime.now());
//        mqServiceAdapter.sendOneWayMessage("test-topic", "syncSendMessage" + LocalDateTime.now());
//        mqServiceAdapter.syncSendMessage("test-topic", "syncSendMessage" + LocalDateTime.now());
//        mqServiceAdapter.asyncSendMessage("test-topic", "asyncSendMessage" + LocalDateTime.now());
//    }
//}
